package com.bougaga.samplespringcloud.kafka.provider.pipeline;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * 定义输出通道并绑定输出通道配置信息
 * @author bougaga
 * OUTPUT_1 = "sourceA" 跟配置文件里面的通道名称 sourceA 保持一致
 */
public interface Source {

	//发送队列1  
    String OUTPUT_1 = "sourceA";  
      
    @Output(Source.OUTPUT_1)  
    MessageChannel output1(); 
}
